package com.source.flinkrpc;

import org.apache.flink.runtime.rpc.RpcEndpoint;
import org.apache.flink.runtime.rpc.RpcService;

/**
 * 自定义Rpc通信实体
 * FlinkRPC通信需要继承RpcEndpoint，实现CustomGateway
 *
 *
 */
public class CustomRpcEndpoint  extends RpcEndpoint implements CustomGateway {


    public CustomRpcEndpoint(RpcService rpcService) {
        super(rpcService);
    }
    @Override
    public String getName() {
        return "Q老师";
    }
}